package com.example.demo.consumer;

import lombok.extern.slf4j.Slf4j;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;

@Slf4j
@Service
public class KafkaConsumerService {


    @KafkaListener(topics = "ZeroMarkets-1-orders",groupId = "my-group-demo")
    public void consume(String message) {
//        System.out.println("Received message: " + message);

        log.info("Received message:{}",message);
    }
}